jjzjj

Java Parallel Streams 关闭线程

全部标签

ruby - 当应用程序关闭时,我要在 Sinatra 中的什么位置放置要执行的代码?

我正在为我的网络应用程序使用Sinatra。当我的应用程序关闭时,我有一些要执行的清理代码。Sinatra中是否有针对此的Hook,还是我必须使用单独的机制? 最佳答案 看Kernel#at_exit,如果您在主应用程序文件中的某处定义这样的block,我不明白为什么它不能在Sinatra应用程序中工作。更新:根据matt的评论,您必须在要求Sinatra之前定义您的at_exit处理程序。 关于ruby-当应用程序关闭时,我要在Sinatra中的什么位置放置要执行的代码?,我们在Sta

ruby - RSpec:使用线程进行测试

在RSpec中,我有创建新线程的函数,并在该线程内执行一些操作——在我的例子中,调用TCPSocket#readline。这是现在的功能:defreadThread.newdowhileline=@socket.readline#TODO:stuffendendend由于线程调度,如果这样写我的测试会失败:it"readsfromsocket"dosubject.socket.should_receive(:readline)subject.readend目前我知道解决这个问题的唯一方法是使用sleep0.1。有没有办法适本地延迟测试,直到该线程运行? 最佳

ruby - 两个Ruby线程相关的问题

第一个:如何创建一个不会立即启动的线程。如果我在没有block的情况下使用initialize,则会引发异常。如何将Thread子类化,以便我可以添加一些自定义属性,但保留与Thread基类相同的功能?我也不想为此使用initialize(&block)方法。为了更好地说明这一点:第一个问题:x=Thread.newx.run={#thisshouldhappeninsidethethread}x.start#iwanttomanuallystartthethread对于第二个:x=MyThread.newx.my_attribute=some_valuex.run={#thissho

ruby-on-rails - rspec 中的多线程 ActiveRecord 请求

我正在尝试在测试中重新创建竞争条件,以便尝试一些解决方案。我发现在我在测试中创建的线程中,ActiveRecord总是为计数返回0,为查找返回nil。例如,表“foos”中有3行:it"whatever"doputsFoo.count5.timesdoThread.newdoputsFoo.countendendend将打印300000test.log显示了预期的查询,预期的6次:SELECTcount(*)AScount_allFROM`active_agents`知道这里发生了什么吗? 最佳答案 我假设ActiveRecord为

ruby - 你能关闭 capybara 中所有打开的窗口吗?

因此,当我单独运行测试时,它们运行良好。但是,当我运行我的功能(多次测试)时,我的代码失败了。这是因为当capybara存在时,并不是我所有的窗口都关闭,因此我的selenium驱动程序不知道要使用哪个窗口。基本上,我的测试正在打开多个窗口。发生这种情况是因为我的测试是单击打开新窗口的链接并检查新窗口中的内容。尽管我在每次测试结束时都说了page.quit,但此函数并没有关闭所有打开的窗口(关闭事件窗口但不关闭原始窗口)。当第二个测试运行时,它使用最初创建的窗口,但是当它打开新的弹出窗口时,它使用了错误的窗口。如何确保在每次测试期间都使用新的浏览器并且关闭之前测试的所有窗口。我目前正在

ruby - 单例类会在多线程应用程序中产生问题吗?

这可能是过早的优化,或过早的过度谨慎,但我避免在一些类上使用单例,因为我担心在未来我需要以多线程方式运行我的应用程序,而且单例会造成冲突和困惑。单例在Ruby中是否有这个问题,或者是否有某种内置的命名空间,以便当一个类引用单例时,只返回同一线程上的单例?编辑:澄清这些是可观察的类,当更新时会导致其他正在观察它们的类更新。我不确定这是否是线程安全的,但我知道现在我正在大量传递这些可观察的类,这有点烦人。而且它们看起来确实像是自然的单例类。 最佳答案 这是一个使单线程安全的例子。您必须像对待任何其他具有状态(@things)并且不是不可

Ruby - 如何在不同线程上的每个数组元素上运行一个方法?

所以我有一个包含40000个元素的数组,我希望对每个元素运行一个方法。为了减少花费的时间,我正在考虑在多个线程上运行它。也许将数组拆分为多个数组并在不同的线程或其他东西上运行。但我不知道如何开始。假设数组是foo[],调用的方法是bar()。bar()返回一个字符串。代码执行后,我希望能够将所有字符串合并/添加到一个大字符串中。有没有办法做到这一点?我试图让我的问题尽可能简单,但如果您想了解更多信息,请告诉我。提前致谢! 最佳答案 听起来您想要类似pmap函数的东西。有一个名为peach的ruby库它在native数组上提供了pma

ruby-on-rails - 如何在开发过程中关闭 Rails 缓存

我正在使用Rails5.2.2,我正在构建一个Web应用程序,它使用我从public目录中提供的一些静态HTML、CSS和JavaScript。大多数情况下,当我更新文件时,它不会在我刷新时在我的浏览器中更新,但如果我进入隐私浏览,它会起作用——直到它再次缓存,然后我需要打开一个新的隐私窗口。如何关闭public文件夹中文件的缓存?或者,如果更简单,我如何在开发过程中关闭所有缓存?这就是我的development.rb的样子。我尝试注释掉整个ifRails.root.join('tmp','caching-dev.txt').exist?block,但这没有做任何事情。如果无法通过设置

Ruby Net::FTP 超时线程

我试图通过使用线程FTP连接来加速多个FTP下载。我的问题是我总是有线程挂起。我正在寻找一种干净的方法来告诉FTP它需要重试ftp事务,或者至少知道FTP连接何时挂起。在下面的代码中,我对5/6个单独的FTP连接进行线程处理,其中每个线程都有一个预期下载的文件列表。当脚本完成时,一些线程挂起并且无法加入。我使用变量@last_updated来表示上次成功下载的时间。如果当前时间+20秒超过了@last_updated,就杀掉剩下的线程。有没有更好的办法?threads=[]max_thread_pool=5running_threads=0Thread.abort_on_excepti

ruby - GMail 线程、IMAP 和 Ruby

我正在使用RubyIMAP库来获取GMail对话。GMail线程对话的方式是通过“Message-ID”和“In-Reply-To”邮件header。例如:In-Reply-To:Message-ID:我不知道如何有效地获取回复消息。当前方式:target=imap.search(["NOT","DELETED"]).eachdo|msg_id|uid=imap.fetch(message_id,"ENVELOPE")[0].attr["ENVELOPE"].message_idifuid==targetm=imap.fetch(msg_id,"RFC822")[0].attr["RF